package com.springcloud.eshop.product.rabbitmq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Repository;

/**
 * @Desc:
 * @Date: 2020-06-29
 * @Version:v1.0
 */
@Repository
@RabbitListener(queues = "eshop-change-queue")
public class RabbitmqConsumer {

    private Logger logger = LoggerFactory.getLogger(RabbitmqConsumer.class);

    @RabbitHandler
    public void handlerMessage(String message) {
        logger.info("RabbitmqConsumer.handlerMessage ,message : {}", message);
    }
}
